/**
 * 指定超时时间
 */

import net from 'node:net'
import { createWriteStream } from 'node:fs'

const server = net.createServer()

const ws = createWriteStream('./06.txt', {
  encoding: 'utf-8'
})

server.on('connection', socket => {

  // 暂停写入
  socket.pause()

  // 设置客户端超时时间， 默认不设置是没有的
  socket.setTimeout(3 * 1000)

  socket.on('timeout', () => {
    console.log('客户端连接超时');
    // 客户端连接，超时后， 做一些事情

    socket.resume()

    socket.pipe(ws)
  })

  socket.on('end', () => {
    console.log('写入完成');
  })

  socket.on('close', () => {
    console.log('断开连接');
  })

})

server.listen(8080, () => {
  console.log('监听 8080');
})